package com.huang.week9.spark

import org.apache.spark.sql.SparkSessionExtensions

class MySparkSessionExtension extends (SparkSessionExtensions => Unit) {
  override def apply(v1: SparkSessionExtensions): Unit = {
    v1.injectOptimizerRule {
      session => new MyPushDown(session)
    }
  }
}
